package com.didispace;

import org.springframework.cloud.stream.annotation.Output;
import org.springframework.cloud.stream.messaging.Sink;
import org.springframework.messaging.MessageChannel;

// 通过注入的方式实现一个消息生成者，向 input 消息通道发送数据。
// 创建一个将 Input 消息通道作为输出通道的接口  p357
public interface SinkSender {

    @Output(Sink.INPUT)
    MessageChannel output();
}
